package com.tl.job014.controller.rest;

import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import com.tl.job014.manager.DataSendManager4Kafka;

/**
 * 
 * @author yingfing
 * @date 2021年3月2日 @time 上午10:49:08
 */
@RestController
public class DataReceiver {

	@RequestMapping("/receiver")
	public void receiver(String message) {
		// System.out.println(message);
		// 以为数据量并不巨大，则直接转发到kafka cluster 即可
		DataSendManager4Kafka.sendData(message);
	}
}
